// 引入mysql
let mysql = require('mysql');
// 引入mysql连接配置
let mysqlconfig = require('../config/mysql');
// 引入连接池配置
let connectionPool = require('./poolextent');
// 使用连接池，提升性能
let pool = mysql.createPool(connectionPool({}, mysqlconfig));

mysqlGetData = {
    query : function(sql,data){
        return new Promise((resolve,reject)=>{
            pool.getConnection(function(err, connection) {
                if(err){
                    reject(err)
                }
                connection.query(sql, data, function(err, result) {
                    // 释放连接
                    connection.release();
                    if(err){
                        reject(err)
                    }
                    resolve(result);
                });
            });
        })
    }
}
module.exports = mysqlGetData;